package rabbitMQ

import (
	amqp "github.com/rabbitmq/amqp091-go"
)

// MQURL 连接信息，格式：amqp://账号:密码@服务器地址:端口号/vhost 默认是 5672 端口
const MQURL = "amqp://simple:123456@8.148.4.43:5672/simple"

// RabbitMQ rabbitMQ 结构体
type RabbitMQ struct {
	conn    *amqp.Connection
	channel *amqp.Channel
	// 队列名称
	QueueName string
	// 交换机名称
	Exchange string
	// bind Key 名称
	Key string
	// 连接信息
	MqURL string
}

// NewRabbitMQ 创建结构体实例
func NewRabbitMQ(queueName, exchange, key string) *RabbitMQ {
	return &RabbitMQ{
		QueueName: queueName,
		Exchange:  exchange,
		Key:       key,
		MqURL:     MQURL,
	}
}

// Destroy 断开 channel 和 connection
func (r *RabbitMQ) Destroy() {
	r.channel.Close()
	r.conn.Close()
}
